package com.yyf.product;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class OrderProducer {
    @Resource
    private RabbitTemplate rabbitTemplate;

    //发送订单消息
    public void sendOrderMessage(String OrderId) {
        String message = "新订单创建：" + OrderId;
        /*
         * 参数说明：
         * - exchange：交换机名
         * - routingKey：路由键
         * - message：消息内容（支持字符串、对象等）
         */
        rabbitTemplate.convertAndSend(
                "order.direct.exchange",//交换机名
                "order.create",//路由键
                message//消息内容
        );
        System.out.println("生产者发送消息：" + message);
    }
}
